package com.shanks.framework.mq.model;

import java.util.Date;

/**
 * 消息消费异常记录
 */
public class MessageConsumeExceptionRecordPO {
    private Long messageConsumeExceptionId;

    private String msgId;

    private String msgTopic;

    private String msgTag;

    private String msgKey;

    /**
     * 消费者
     */
    private String consumer;


    /**
     * 消费异常时间
     */
    private Date consumeExceptionTime;

    private Date deleteTime;

    private Boolean deleteFlag;

    public Long getMessageConsumeExceptionId() {
        return messageConsumeExceptionId;
    }

    public void setMessageConsumeExceptionId(Long messageConsumeExceptionId) {
        this.messageConsumeExceptionId = messageConsumeExceptionId;
    }

    public String getMsgId() {
        return msgId;
    }

    public void setMsgId(String msgId) {
        this.msgId = msgId;
    }

    public String getMsgTopic() {
        return msgTopic;
    }

    public void setMsgTopic(String msgTopic) {
        this.msgTopic = msgTopic;
    }

    public String getMsgTag() {
        return msgTag;
    }

    public void setMsgTag(String msgTag) {
        this.msgTag = msgTag;
    }

    public String getMsgKey() {
        return msgKey;
    }

    public void setMsgKey(String msgKey) {
        this.msgKey = msgKey;
    }

    public String getConsumer() {
        return consumer;
    }

    public void setConsumer(String consumer) {
        this.consumer = consumer;
    }

    public Date getDeleteTime() {
        return deleteTime;
    }

    public void setDeleteTime(Date deleteTime) {
        this.deleteTime = deleteTime;
    }

    public Boolean getDeleteFlag() {
        return deleteFlag;
    }

    public void setDeleteFlag(Boolean deleteFlag) {
        this.deleteFlag = deleteFlag;
    }

    public Date getConsumeExceptionTime() {
        return consumeExceptionTime;
    }

    public void setConsumeExceptionTime(Date consumeExceptionTime) {
        this.consumeExceptionTime = consumeExceptionTime;
    }
}
